import os
from celery import Celery

# 配置celery 加载settings
# 配置环境变量 让我们的celery 能够找到django环境
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'jt32.settings')
# 给celery 取一个应用名
app = Celery("jt32")
# 配置redis的连接信息  消息队列  结果队列
app.config_from_object('celery_tasks.celery_config')

# 处理任务
# 指定处理任务的功能函数所在位置
# @app.task()  指定的功能函数
app.autodiscover_tasks(["celery_tasks.email"])



